
let db // 数据库
let log // 日志方法

/**
 * 演示程序
 * @param Object event request body 数据 
 * @param Object userinfo 当前用户信息
 * @param fastify server fastify
 * @returns 
 */
module.exports = async (event, userinfo, server) => {
  // 获取fastify 方法
  log = server.log
  // 连接数据库
  db = server.database
  // 处理程序
  switch (event.action) {
    case 'add':
      return await add(event.data)
    case 'getlist':
      return await getlist()
    default:
      return false;
  }
}

async function getlist() {
  try {
    const res = await db.collection('test').find({
      data: {
        name: '11111'
      }
    }).toArray()
    return res
  } catch (error) {
    log.error(`function error: ${error}`)
  }
}


async function add(data) {
  try {
    const res = await db.collection('test').insertOne({
      data
    })
    return {
      _id: res.insertedId
    }
  } catch (error) {
    log.error(`function error: ${error}`)
  }
}